package weaver.interfaces.jz.action;

import com.alibaba.fastjson.JSONObject;
import com.engine.common.util.ServiceUtil;
import com.engine.jz.service.JzjgService;
import com.engine.jz.service.impl.JzjgServiceImpl;
import org.apache.commons.lang3.StringUtils;
import weaver.conn.RecordSet;
import weaver.general.BaseBean;
import weaver.hrm.User;
import weaver.interfaces.workflow.action.Action;
import weaver.soa.workflow.request.RequestInfo;
import weaver.workflow.request.RequestManager;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.UUID;

/**
 * @version 1.0
 * @Title ecology-9
 * @Company 泛微软件
 * @CreateDate 2024/11/28
 * @Description 人员更新同步设备Action
 * @Author AdminZm
 */
public class HrmUpdateSyncDeviceAction implements Action {

    BaseBean baseBean = new BaseBean();

    public JzjgService getJzjgService(User user) {
        return ServiceUtil.getService(JzjgServiceImpl.class, user);
    }

    @Override
    public String execute(RequestInfo requestInfo) {
//        RequestManager requestManager = requestInfo.getRequestManager();
//        int billId = requestManager.getBillid();
//        String tableName = requestManager.getBillTableName();
//        String requestId = requestInfo.getRequestid();
//        User user = requestManager.getUser();
//        baseBean.writeLog("HrmUpdateSyncDeviceAction start:" + requestId);
//        RecordSet rs = new RecordSet();
//        RecordSet rs1 = new RecordSet();
//        try {
//            String gh = null;
//            String xm = null;
//            String sfzhm = null;
//            String kqj = null;
//            String rytx = null;
//            rs.executeQuery("SELECT * FROM " + tableName + " WHERE id = ?", billId);
//            if (rs.next()) {
//                gh = rs.getString("gh");
//                xm = rs.getString("xm");
//                sfzhm = rs.getString("sfzhm");
//                kqj = rs.getString("kqj");
//                rytx = rs.getString("rytx");
//            }
//            if (StringUtils.isEmpty(kqj)) {
//                baseBean.writeLog("HrmUpdateSyncDeviceAction kqj is null.");
//                return Action.SUCCESS;
//            }
//
//            String modeId = rs.getPropValue("jzjg_zm_prop", "tssbjl_mode_id");
//            String cusId = rs.getPropValue("jzjg_zm_prop", "tssbjl_cus_id");
//            SimpleDateFormat sdfDate = new SimpleDateFormat("yyyy-MM-dd");
//            SimpleDateFormat sdfTime = new SimpleDateFormat("HH:mm:ss");
//
//            // 查询设备信息
//            rs.execute("SELECT * FROM uf_kqsbdzgxgljmb WHERE id in (" + kqj + ")");
//            while (rs.next()) {
//                String id = rs.getString("id");
//                String sblx = rs.getString("sblx");
//                String sbxlh = rs.getString("sbxlh");
//                String sbip = rs.getString("sbip");
//
//                // 天波
//                if (StringUtils.equals(sblx, "0")) {
//
//                }
//                // 旷视
//                if (StringUtils.equals(sblx, "1")) {
//                    Map<String, Object> ksParamMap = new HashMap<>();
//                    // 人员id
//                    ksParamMap.put("id", gh);
//                    // 人员姓名
//                    ksParamMap.put("person_name", xm);
//                    // 人员编号
//                    ksParamMap.put("person_code", gh);
//                    // 身份证号码，需要aes加密
//                    if (StringUtils.isNotEmpty(sfzhm)) {
//                        ksParamMap.put("id_number", sfzhm);
//                    }
//                    // 身份证号码，需要aes加密
//                    if (StringUtils.isNotEmpty(rytx)) {
//                        ksParamMap.put("rytx", rytx);
//                    }
//                    String uuid = UUID.randomUUID() + "-" + gh;
//                    rs1.executeUpdate("INSERT INTO uf_tssbjlglb (sb,qqid,qqcsjmq,zt,tslx, formmodeid,MODEUUID,modedatacreater," +
//                            "modedatacreatertype, modedatacreatedate, modedatacreatetime) VALUES (?,?,?,?,?,?,?,?,?,?,?)",
//                            id, requestId, JSONObject.toJSONString(ksParamMap), "0", "0", modeId, uuid, "1",
//                            "0", sdfDate.format(new Date()), sdfTime.format(new Date()));
//                    String dataId = null;
//                    rs1.executeQuery("SELECT id FROM uf_tssbjlglb WHERE MODEUUID = ?", uuid);
//                    if (rs1.next()) {
//                        dataId = rs1.getString("id");
//                    }
//                    getJzjgService(user).pushHrmToKs(sbip, ksParamMap, dataId);
//                }
//
//                // 中控
//                if (StringUtils.equals(sblx, "2")) {
//
//                }
//            }
//
//        } catch (Exception e) {
//            baseBean.writeLog("HrmUpdateSyncDeviceAction error:" + e);
//        }
        return Action.SUCCESS;
    }
}
